package com.adcc.ags.cgw.service;

import com.adcc.ags.cgw.entity.msg.TrafficMsg;
import com.adcc.ags.cgw.proxy.UserProxy;
import com.adcc.utility.log.Log;

/**
 * 消息报文服务
 */
public class MsgSaverServiceImpl extends MsgSaverService {

    @Override
    public void onReceive(Object message) {
        super.onReceive(message);
        try {
            TrafficMsg msg = (TrafficMsg) message;
            UserProxy.getInstance().saveMsg(msg);
        } catch (Exception ex) {
            Log.error(MsgSaverService.class.getName(), "onReceive() error", ex);
        }
    }
}
